0.4.7

libnexakotlin/org.nexa.libnexakotlin.socketKtor/[linux]TcpSocket

TcpSocket

class TcpSocket(val sendCtxt: CoroutineContext, val receiveCtxt: CoroutineContext) : iTcpSocket

Constructors

constructor(sendCtxt: CoroutineContext, receiveCtxt: CoroutineContext)

Properties

availableForRead

open override val availableForRead: Int

Returns number of bytes that can be read without blocking

var inp: ByteReadChannel?

open override val localAddress: SocketAddress

var out: ByteWriteChannel?

val receiveCtxt: CoroutineContext

open override val remoteAddress: SocketAddress

selectorManager

var selectorManager: SelectorManager

val sendCtxt: CoroutineContext

var sock: Socket?

var sockBuilder: TcpSocketBuilder

Functions

fun awaitContent(scope: CoroutineScope, cb: () -> Unit)

open override fun close()

open override fun connect(name: String, port: Int, connectTimeout: Int, sockOptions: SocketOptions.() -> Unit?)

open override fun finalize()

open override fun flush()

force any writes to actually be sent

open override fun isAlive(): Boolean

open override fun readAvailable(dst: ByteArray, offset: Int, length: Int): Int

open override fun writeFully(src: ByteArray, offset: Int, length: Int)

Writes all src bytes and suspends until all bytes written. Causes flush if buffer filled up or when autoFlush Crashes if channel get closed while writing

fun iTcpSocket.writeFully(str: String)